package com.test.spi.impl;

import com.test.interceptor.InterceptHandler;
import com.test.interceptor.messages.InterceptConnectMessage;
import com.test.interceptor.messages.InterceptDisconnectMessage;
import com.test.interceptor.messages.InterceptPublishMessage;
import com.test.interceptor.messages.InterceptSubscribeMessage;
import com.test.interceptor.messages.InterceptUnsubscribeMessage;

public class InterceptorHandlerImpl implements InterceptHandler {

	@Override
	public void onConnect(InterceptConnectMessage msg) {
		System.out.println("onConnect..........");
		System.out.println(msg);
	}

	@Override
	public void onDisconnect(InterceptDisconnectMessage msg) {
		System.out.println("onDisconnect..........");
		System.out.println(msg);
	}

	@Override
	public void onPublish(InterceptPublishMessage msg) {
		System.out.println("onPublish..........");
		System.out.println(msg);
	}

	@Override
	public void onSubscribe(InterceptSubscribeMessage msg) {
		System.out.println("onSubscribe..........");
		System.out.println(msg);
	}

	@Override
	public void onUnsubscribe(InterceptUnsubscribeMessage msg) {
		System.out.println("onUnsubscribe..........");
		System.out.println(msg);
	}
	

}
